package com.sikaryofficial.backend.message.product;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * output 生产者接口定义
 */
public interface MQProduct {

    String BINDINGS_ACTIVITY_PURCHASE_OUTPUT = "activity-purchase-output";

    String BINDINGS_SCAN_REGISTER_OUTPUT = "scan-register-output";

    String BINDINGS_LOTTERY_OUTPUT = "lottery-output";

    String BINDINGS_ACTIVITY_RESULT_USERINFO_OUTPUT = "activity-result-userinfo-output";

    @Output(BINDINGS_ACTIVITY_RESULT_USERINFO_OUTPUT)
    MessageChannel activityResultModifyOutput();

    @Output(BINDINGS_ACTIVITY_PURCHASE_OUTPUT)
    MessageChannel attendOutput();

    @Output(BINDINGS_SCAN_REGISTER_OUTPUT)
    MessageChannel scanRegisterOutput();

    @Output(BINDINGS_LOTTERY_OUTPUT)
    MessageChannel lotteryOutput();
}
